package com.tyf.common.rabbitmq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * 
 * @author tan.bin
 * @date 2017/02/21
 */
public interface ChannelInput {
	/*
	 * 通道
	 * The core API classes are Connection and Channel, 
	 * representing an AMQP 0-9-1 connection and an channel, respectively. 
	 * They are typically imported before used:
	 * 通过定义:多个队列可以共用一个通道，一个通道可以管理多个队列
	 * 根据业务量大.实时高.就独立通道
	 */
	String INPUT_CHANNEL_UC ="input_channel_uc"; //输入类型的通道
	
	String INPUT_CHANNEL_MDM ="input_channel_mdm"; //输入类型的通道
	
	String INPUT_CHANNEL_SD ="input_channel_sd"; //输入类型的通道

	String INPUT_CHANNEL_MM ="input_channel_mm"; //输入类型的通道

	String INPUT_CHANNEL_PP ="input_channel_pp"; //输入类型的通道

	String INPUT_CHANNEL_QM ="input_channel_qm"; //输入类型的通道

	String INPUT_CHANNEL_GL ="input_channel_general"; //输入类型通用通道
	
	//通用通道
	@Input(ChannelInput.INPUT_CHANNEL_GL)
	SubscribableChannel PullInputGL();
}
